<?php 
namespace Task;
use Lib\MongoUtil;

/**
* 这仅仅是一个测试的任务类而已
* 每个任务类可以不继承Task,但必须要有一个run的入口方法
*/
class Demo extends Task
{
	
	public function run()
	{	
		$Mongo=MongoUtil::init();

		$Model=M('users');

		$total=$Mongo->count('erp_users');

		$unit=10000;

		$i=0;
		$t=0;
		
		while ($i<ceil($total/10000)) {
			
			$start=$i*$unit;

			$users=$Mongo->find('erp_users',[],['skip'=>$start,'limit'=>$unit]);

			foreach ($users as $key => $user) {
				$data=[];
				$data=$user+$user['receive_infos'][0];
				unset($data['receive_infos']);
			
				$Model->add($data);

				console($t);

				$t++;
			}
			$i++;
			
		}
	
	}
}




?>